package com.we.flink.dcapiuserlabel.table;

import java.sql.Timestamp;

public class TableTaskUser {
    public static final String KFKTABLE = "fdm.rrd07_task_user";
    public static final String QUERYSQL =
            "select id as connect_id, uid, update_time from "
                    + KFKTABLE
                    + " where update_time is not null";

    public int uid;
    public int connect_id;
    public Timestamp update_time;

    public TableTaskUser() {}

    public TableTaskUser(int uid, int connect_id, Timestamp update_time) {
        this.uid = uid;
        this.connect_id = connect_id;
        this.update_time = update_time;
    }

    public int getUid() {
        return uid;
    }

    public int getConnect_id() {
        return connect_id;
    }

    public Timestamp getUpdate_time() {
        return update_time;
    }
}
